package org.idea.qiyu.framework.rocketmq.annotation;

import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;
import org.springframework.stereotype.Component;

import java.lang.annotation.*;

/**
 * @Author linhao
 * @Date created in 9:08 上午 2021/6/30
 */
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Component
public @interface QiyuConsumer {

    String topic() default "";

    String tag() default "*";

    String groupName() default "";

    MessageModel messageModel() default MessageModel.CLUSTERING;

    ConsumeFromWhere consumeFromWhere() default ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET;

//    Class consumeMessageHook();
}
